package com.tengju.data.domain.model.cdc;

/**
 * @author chenhang
 * @Date 2021/9/29
 */
public interface CdcUserRepository {



    void deleteByIdCode(long idCode);


    /**
     * 解析binlog顺序可能错乱
     * 先查询是否有数据，若无直接插入
     * 若有数据判断数据更新时间，若binlog数据在更新之前的之前丢弃，否则更新数据
     * @param idCode
     * @param pIdCode
     * @param level
     * @param levelChangeTime
     * @param sourceChangeTime
     */
    void saveOrUpdateByCdc(long idCode, long pIdCode, int level, String levelChangeTime, String sourceChangeTime);

}
